package org.onion.pattern.event.consumer.log;

import lombok.Data;

import java.time.LocalDateTime;

@Data
public class EventConsumeLog {

    private String                 id;
    private String                 msgId;
    private String                 eventKey;
    private String                 topic;
    private String                 subTopic;
    private String                 channel;
    private Integer                reconsumeTimes;
    /**
     * 消费状态
     */
    private EventConsumeStatusEnum consumeStatus;
    /**
     * 异常
     */
    private String                 exceptionStack;
    /**
     * 消费组
     */
    private String                 consumerGroup;
    /**
     * 事件产生时间
     */
    private LocalDateTime          eventTime;
    /**
     * 事件已发布时间
     */
    private LocalDateTime          publishedTime;
    /**
     * 事件收到时间
     */
    private LocalDateTime          receiveTime;
    /**
     * 事件消费时间
     */
    private LocalDateTime          consumedTime;

//            `queue_id` int NOT NULL DEFAULT '0' COMMENT '队列编号',
//            `broker` varchar(255) NOT NULL DEFAULT '',
//            `message_offset` bigint NOT NULL DEFAULT '0' COMMENT '偏移量',

//            `born_time_stamp` bigint NOT NULL DEFAULT '0',
//            `properties` text COMMENT '属性集合',

}
